package spring;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

/** 
* @author 朱宏亮
* @version 创建时间：2017年12月7日 下午2:10:02 
* 类说明 
*/
public class ProducerTopic {

    
    public static void main(String[] args) {  
        System.out.println("发送消息 开始!");  
        ApplicationContext ctx = new ClassPathXmlApplicationContext( "spring/ProducerTopic.xml");  
        JmsTemplate jt = null;  
        // 获取JmsTemplate对象  
        jt = (JmsTemplate) ctx.getBean("jmsTemplate3");  
        // 调用方法，发送消息  

        jt.send(new MessageCreator() {  
            // 消息的产生，返回消息发送消息  
            public Message createMessage(Session s) throws JMSException {  
                TextMessage msg = s.createTextMessage("Spring 发送Topic消息 ----> 你好 ActiveMQ");  
                return msg;  
            }  
        });  
        
        System.out.println("发送消息 结束!");  
        System.exit(0);//因与ActiveMQ的连接没结束，手动结束程序
    }  
}
 